package cn.me.implement.threadpool.reject;

import cn.me.implement.threadpool.JaneThreadPool;

/**
 * <strong>抛出异常</strong> 的拒绝策略
 */
public class ThrowRejectPolicy implements RejectPolicy {

    @Override
    public void reject(Runnable rejectTask, JaneThreadPool threadPool) {
        throw new RuntimeException("任务队列已满");
    }
}
